import requests
import json


def infer(xinput, username=''):
    """用函数对运行的Flask程序flask_demo.py进行封装。"""
    # 组织输入
    xjson = dict()
    xjson['input'] = xinput

    # 获取输出
    res = requests.post('http://127.0.0.1:6666/api', json=xjson)

    # 解析输出
    xjson = json.loads(res.text)
    xouput = xjson['output']

    # 返回结果
    return xouput


if '__main__' == __name__:

    import threading

    def invoke(xinput):
        # 调用封装的函数
        xoutput = infer(xinput)
        print('output:', xoutput)
        
    xlist = [
        '很好吃呀', 
        '一般般呀……',
        '人间难得几回吃！',
        '人间难得几回吃！师傅精湛的厨艺让我们想起蓝翔技校那光辉的岁月。',
        '太难吃了！',
        '太好吃了！',
        '经典鲁菜！！这糖醋里脊，永远吃不腻！',
        'Yes, 很好吃呀', 
        'No, 一般般呀……',
        'Yes, 人间难得几回吃！',
        'Yes, 人间难得几回吃！师傅精湛的厨艺让我们想起蓝翔技校那光辉的岁月。',
        'No, 太难吃了！',
        'Yes, 太好吃了！',
        'Yes, 经典鲁菜！！这糖醋里脊，永远吃不腻！',
    ]
    
    for xinput in xlist:
        th = threading.Thread(target=invoke, args=(xinput, ))
        th.start()
